package com.jml.consumer;

import com.jml.entity.MsgEntity;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@RabbitListener(queues = "fanout_sms_queue")
public class FanoutSmsConsumer {

    @RabbitHandler
    public void process(MsgEntity msgEntity) {
        System.out.println("短信消费者获取生产者消息msg:" + msgEntity);
    }
}
